Implement streaming communication

[KaMeHb-UA]

Streams must be an internal-created async iterable objects instead of bufferized streams.

• Readable must implement:

1. [Symbol.asyncIterable](): AsyncIterator
2. catch(callback: (error: Error) => void): void
3. stop(): Promise<void>

• Writable must implement:

1. next(value: any): Promise<void>
2. throw(error: Error): Promise<void>
3. stop(): Promise<void>

• Duplex must implement:

1. [Symbol.asyncIterable](): AsyncIterator
2. next(value: any): Promise<void>
3. catch(callback: (error: Error) => void): void
4. throw(error: Error): Promise<void>
5. stop(): Promise<void>