| 911 | |
| 912 | AsyncBuffersPool& AsyncWritableStream::getBuffersPool() { return *buffers; } |
| 913 | |
| 914 | void AsyncWritableStream::emitError(Result error) { eventError.emit(error); } |
| 915 | //------------------------------------------------------------------------------------------------------- |
| 916 | // AsyncDuplexStream |
| 917 | //------------------------------------------------------------------------------------------------------- |
| 918 | |
| 919 | AsyncDuplexStream::AsyncDuplexStream() {} |
| 920 | |
| 921 | Result AsyncDuplexStream::asyncRead() { return Result(true); } |
| 922 | |
| 923 | Result AsyncDuplexStream::init(AsyncBuffersPool& buffersPool, Span<AsyncReadableStream::Request> readableRequests, |
| 924 | Span<AsyncWritableStream::Request> writableRequests) |
| 925 | { |
| 926 | AsyncReadableStream::setReadQueue(readableRequests); |
| 927 | AsyncWritableStream::setWriteQueue(writableRequests); |
| 928 | SC_TRY(AsyncReadableStream::init(buffersPool)); |
| 929 | SC_TRY(AsyncWritableStream::init(buffersPool)); |
| 930 | return Result(true); |
| 931 | } |
| 932 | |
| 933 | //------------------------------------------------------------------------------------------------------- |
| 934 | // AsyncTransformStream |
| 935 | //------------------------------------------------------------------------------------------------------- |
| 936 | AsyncTransformStream::AsyncTransformStream() {} |
| 937 | |
| 938 | Result AsyncTransformStream::asyncWrite(AsyncBufferView::ID bufferID, Function<void(AsyncBufferView::ID)> cb) |
| 939 | { |
nothing calls this directly
no test coverage detected