AsyncIO

KO | EN

gitlite — search

#deep-learning #rag #swift #mysql #redis #computer-vision #react-native #chatbot #framework #html

(★ 31)

Delphi.AsyncIO library

파일 탐색기

ZIP 다운로드

- AsyncIO.Test.AsyncReadUntil.pas
- AsyncIO.Test.Basic.pas
- AsyncIO.Test.Copy.pas
- AsyncIO.Test.Socket.pas
- AsyncIO.Test.StreamReader.pas
- AsyncIODev.dpr
- AsyncIODev.dproj
- AsyncIODev.res
- TestData.txt
- - AsyncFileCopy.dpr
  - AsyncFileCopy.dproj
  - AsyncFileCopy.Impl.pas
  - AsyncFileCopy.res
- - AsyncHttpClient.dpr
  - AsyncHttpClient.dproj
  - AsyncHttpClient.Impl.pas
  - AsyncHttpClient.res
  - AsyncHttpServer.Connection.pas
  - AsyncHttpServer.ConnectionManager.pas
  - AsyncHttpServer.dpr
  - AsyncHttpServer.dproj
  - AsyncHttpServer.ficfg
  - AsyncHttpServer.Headers.pas
  - AsyncHttpServer.Impl.pas
  - AsyncHttpServer.Mime.pas
  - AsyncHttpServer.Request.pas
  - AsyncHttpServer.RequestHandler.pas
  - AsyncHttpServer.RequestParser.pas
  - AsyncHttpServer.res
  - AsyncHttpServer.Response.pas
  - HttpDateTime.pas
- - AsyncEchoClient.dpr
  - AsyncEchoClient.dproj
  - AsyncEchoClient.Impl.pas
  - AsyncEchoClient.res
- AsyncIO.Coroutine.Detail.Fiber.pas
- AsyncIO.Coroutine.Detail.pas
- AsyncIO.Coroutine.Net.IP.pas
- AsyncIO.Coroutine.pas
- AsyncIO.Detail.pas
- AsyncIO.Detail.StreamBufferImpl.pas
- AsyncIO.Filesystem.Detail.pas
- AsyncIO.Filesystem.pas
- AsyncIO.Net.IP.Detail.pas
- AsyncIO.Net.IP.Detail.TCPImpl.pas
- AsyncIO.Net.IP.pas
- AsyncIO.OpResults.pas
- AsyncIO.pas
- AsyncIO.StreamReader.pas
- AsyncIOTestCase.pas
- AsyncIOTests.dpr
- AsyncIOTests.dproj
- AsyncIOTests.res
- EchoTestClient.pas
- EchoTestServer.pas
- IPStreamSocketMock.pas
- NetTestCase.pas
- Test.AsyncIO.Detail.pas
- Test.AsyncIO.Net.IP.Detail.pas
- Test.AsyncIO.Net.IP.Detail.TCPImpl.pas
- Test.AsyncIO.Net.IP.pas
.gitattributes
.gitignore
AsyncIO.groupproj
LICENSE
README.md

# CDN으로 사용하기

jsDelivr

jsDelivr는 공개 GitHub 리포지토리를 별도 설정 없이 CDN으로 즉시 서빙합니다. 버전과 파일을 고르면 웹페이지에 바로 붙일 수 있는 링크와 예시 코드가 만들어집니다.

버전

파일

링크

예시

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

Delphi.AsyncIO library, inspired by Boost.ASIO.

Under development! Currently mostly for fun.

Uses IOCP under the hood.

## TPC echo client example

Library is under development, but this should show the direction.

```delphi
type
  EchoClient = class
  private
    FRequest: string;
    FData: TBytes;
    FSocket: IPStreamSocket;
    FStream: AsyncSocketStream;

procedure HandleConnect(const ErrorCode: IOErrorCode);
    procedure HandleWrite(const ErrorCode: IOErrorCode; const BytesTransferred: UInt64);
    procedure HandleRead(const ErrorCode: IOErrorCode; const BytesTransferred: UInt64);
  public
    constructor Create(const Service: IOService;
      const ServerEndpoint: IPEndpoint;
      const Request: string);
  end;

procedure TestEcho;
var
  qry: IPResolver.Query;
  res: IPResolver.Results;
  ip: IPResolver.Entry;
  ios: IOService;
  client: EchoClient;
  r: Int64;
begin
  qry := Query(IPProtocol.TCP.v6, 'localhost', '7', [ResolveAllMatching]);
  res := IPResolver.Resolve(qry);

ip := res[0]; // TODO - make connect take resolver result set, connect until success

ios := nil;
  client := nil;
  try
    ios := NewIOService;

WriteLn('Connecting to ' + ip.Endpoint);

client := EchoClient.Create(ios, ip.Endpoint, 'Hello Internet!');

r := ios.Run;

WriteLn;
    WriteLn('Done');
  finally
    client.Free;
  end;
end;

{ EchoClient }

constructor EchoClient.Create(
  const Service: IOService;
  const ServerEndpoint: IPEndpoint;
  const Request: string);
begin
  inherited Create;

FRequest := Request;

FSocket := NewTCPSocket(Service);

FSocket.AsyncConnect(ServerEndpoint, HandleConnect);
end;

procedure EchoClient.HandleConnect(const ErrorCode: IOErrorCode);
begin
  if (not ErrorCode) then
    RaiseLastOSError(ErrorCode.Value);

WriteLn('Client connected');
  WriteLn('Local endpoint: ' + FSocket.LocalEndpoint);
  WriteLn('Remote endpoint: ' + FSocket.RemoteEndpoint);
  WriteLn('Sending echo request');

// encode echo request
  FData := TEncoding.Unicode.GetBytes(FRequest);

// use a socket stream for the actual read/write operations
  FStream := NewAsyncSocketStream(FSocket);

AsyncWrite(FStream, FData, TransferAll(), HandleWrite);
end;

procedure EchoClient.HandleWrite(const ErrorCode: IOErrorCode;
  const BytesTransferred: UInt64);
begin
  if (not ErrorCode) then
    RaiseLastOSError(ErrorCode.Value);

// half close
  FSocket.Shutdown(SocketShutdownWrite);

// zero our response buffer so we know we got the right stuff back
  FillChar(FData[0], Length(FData), 0);

AsyncRead(FStream, FResponseData, TransferAtLeast(Length(FData)), HandleRead);
end;

procedure EchoClient.HandleRead(const ErrorCode: IOErrorCode;
  const BytesTransferred: UInt64);
var
  s: string;
  responseMatches: boolean;
begin
  if (not ErrorCode) then
    RaiseLastOSError(ErrorCode.Value);

// decode echo response
  s := TEncoding.Unicode.GetString(FData, 0, BytesTransferred);

WriteLn('Echo reply: "' + s + '"');

FSocket.Close();

// stopping to be improved
  FStream.Socket.Service.Stop;
end;
```

Output from the above program:
```
Connecting to [::1]:7
Client connected
Local endpoint: [::1]:61659
Remote endpoint: [::1]:7
Sending echo request
Echo reply: "Hello Internet!"

Done
```

## License

Licensed under the Apache 2.0 license, see LICENSE file for details.

AsyncIO

오너의 다른 레포

파일 탐색기

# CDN으로 사용하기

Was this content helpful?

Recent Feedback

AsyncIO

오너의 다른 레포

파일 탐색기

# CDN으로 사용하기

Was this content helpful?

Recent Feedback

Download README