Skip to content

Conversation

@bigbigc0
Copy link

ValueTask Send(ReadOnlyMemory data);
ValueTask Send(IPackageEncoder packageEncoder, TSendPackage package);
返回发送字节数

ValueTask<int> Send(ReadOnlyMemory<byte> data);
ValueTask<int> Send<TSendPackage>(IPackageEncoder<TSendPackage> packageEncoder, TSendPackage package);
返回发送字节数

public abstract ValueTask SendAsync(Action<PipeWriter> write);

public abstract ValueTask<int> Send(ReadOnlyMemory<byte> buffer);
Copy link
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Send => SendAsync?


public abstract ValueTask<int> Send(ReadOnlyMemory<byte> buffer);

public abstract ValueTask<int> Send<TPackage>(IPackageEncoder<TPackage> packageEncoder, TPackage package);
Copy link
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Send => SendAsync?


ValueTask<int> Send<TPackage>(IPackageEncoder<TPackage> packageEncoder, TPackage package);


Copy link
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Extra line?>


WritePackageWithEncoder(arrayBufferWriter, packageEncoder, package);

return await SendOverIOAsync(new ReadOnlySequence<byte>(arrayBufferWriter.WrittenMemory), CancellationToken.None);
Copy link
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Extra space.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants