??

???? ??? ? ?? ??? ????? ???? ???? ? ???? ???? ?? ?????. ???? ????? ??? ? ?? ???? ????? ???? ??? ????? ? ??? ???. ???? ??? ???? ???? ????. ??? ??? ??, ?? I/O, ???? ?? ? ??? ????? ??? ? ????. Node.js?? ???? ??? ??? ??? ???? ?????? ??? ????? ? ?? ?????.

? ????? ??? ???? ????? ????? Node.js?? ???? ???? ??? ???? ???? ??? ?????. ??? ????? ??? Node.js? ?? ??? ???? ?? ???? ??? ???? ?? ?? ??? ???? ????.

?? ??

???? ??? ???? ?? ???? ???? ????? ???? ?? ??? ? ????. ???? ??? ????? ??? ?????? ?? ? ??? ??? ? ????. ??? ???? ??? ???? ??? ??? ??? ??? ?? ??, ??? ??? ??, ???? ?? ??? ? ??? ?? ??? ???? ???? ????.

? ?? ??? ???? ??? ???? ?? ??? ???? Node.js??? ?? ?? ??? ???? ??? ??? ???? ????. ??? ??? ????? ???? ????? ??? ? ??? ?? ?????? ???? ??? ??? ? ??? ??? ???.

??? ??

???? ??? ??

??? ??? ?????? ? ??(??? ??? ???)? ???(?????? ???? ???)? ??? ???. ??? ?? ???? ???? ?? ??? ?? ?? ??? ????? ? ????. ?? ???? ???? ?? ??? ??? ??? ???? ???? ?? ??? ? ????.

????? Node.js? ???? ???? ??? ????? ??? ? ????. ?? ??? ??? ???? ???? ?? ? ?? ??? ??? ? ???? ???? ?? ????? ???? ??? ???? ??? ? ????.

?? ? ? ???

??? ????? ????? ??? ??? ???? ? ??? ???? ? ?? ?? ?? ??? ????. Node.js? ?? ????? ???? ???? ????? ????? ??? ??? ???? ?? ?????.

?? ???

?? ?? ???? ????? ??? ???? ???? ???? ?? ????? ????? ????. ? ?? ??? ??? ????, ???? ??? ???? ?? ????? ????? ?????. ? ??? WebSocket, ?? ?? ??? ?? RxJS? ?? ??? ????? ?????? ?? ??? ????? ??? ?????? ?? ?????. ?? ???? ??? ???? ?????? ?? ??? ? ??? ???? ??? ??? ??? ??? ??? ??????? ?????.

? ???

??? ? ?? ???? ??? ???? ???? ??? ?? ????? ???? ??? ? ????. ???? ??? ?? ?????? ???? ?????? ???? "?????". ? ?? ??? ?? ?? ?? ??, Node.js ??? ? ????? ??????. ? ??? ??? ?? ??? ??? ?? ????? ? ?? ???? ????? ??? ??? ??? ????? ??? ???? ???? ? ??? ? ? ????.

? ? ?? ?? ??? ???? ??? ??? ??? ????, ??? ??? ??? ??? ???? ? ??? ?? ??? ??? ???? ??? ???? ? ??? ???.

Node.js? ???

???? ??? ??? ?? ????. ?? ? ??? ??? ?? ???? ???? ? ?? Unix ?????? ??? ?? ????. Node.js? ?????? ???? ???? ???? ???? ?? ? ??? ?????. ???? ???? ??? ?? ??? ? ?? ??? ???? ?????.

Node.js ???? ? ?? ???? ?????. ?, ???? ?? ???? ?? ?????. ?? Node.js? ??? ??? ?? ????? ???? ??? ??? ????? ??????? ???? ???? ????? ?????.

??? ??

Node.js? ?? ?? ??? ??? ?? ??? ???? ?????.

1. ?? ??? ???: ? ???? ???? ???? HTTP ??? ?? ???? ???? ?? ? ????. ??? ??? ???? ???? ??? ??? ???.

2. ?? ??? ???: ? ???? ???? ???? ???? ??? ?? ??? ???? ? ? ????. ?? ???? ????? ????? ???? ??? ??? ???.

3. ?? ???: ? ???? ???? ?? ? ? ????. ???? ???? ???? ???? ??? ?? ??? ??? ??? ?????.

4. ??? ??: ??? ???? ???? ??? ? ???? ????? ?????. ?? ?? ??? ???? ?? ?? ?? ????.

?? ???? ???? ?

? ???? ?? ??, ?? ? ?? ?? ???? ???? Node.js?? ??? ??? ?? ?????? ???? ??? ?????. ??? ??? ??? ????.

??? ??? ??: ?? ??? ???? ???? ??? ???? ?? ???? ?????.
??? ??: ?? ???? ???? ? ???? ???? ???? ?? ???? ?????.
??? ??: ?? ??? ???? ???? ??? ???? ??? ?????.

????? ??? ???? ??? ???? ?? ???? ???? ? ????? ?? ????? ???? ???? ?? ??? ? ?? ??? ?????.

?? ??

???? ?? ?????? ?? ??? ??? ????.

const { pipeline } = require('stream');
const { Readable, Writable, Transform } = require('stream');

// Create a Readable stream that generates a sequence of strings

class StringStream extends Readable {

  constructor(options) {

    super(options);

    this.strings = ['Hello', 'World', 'This', 'Is', 'A', 'Test'];

    this.index = 0;

  }

  _read(size) {

    if (this.index < this.strings.length) {

      this.push(this.strings[this.index]);

      this.index++;

    } else {

      this.push(null); // End of stream

    }

  }

}

// Create a Transform stream that converts data to uppercase

class UppercaseTransform extends Transform {

  _transform(chunk, encoding, callback) {

    this.push(chunk.toString().toUpperCase());

    callback(); // Signal that the transformation is complete

  }

}

// Create a Writable stream that prints data to the console

class ConsoleWritable extends Writable {

  _write(chunk, encoding, callback) {

    console.log(`Writing: ${chunk.toString()}`);

    callback(); // Signal that the write is complete

  }

}

// Create instances of the streams

const readableStream = new StringStream();

const transformStream = new UppercaseTransform();

const writableStream = new ConsoleWritable();

// Use pipeline to connect the streams

pipeline(

  readableStream,

  transformStream,

  writableStream,

  (err) => {

    if (err) {

      console.error('Pipeline failed:', err);

    } else {

      console.log('Pipeline succeeded');

    }

  }

);

?? ??

?? ??? ???(StringStream):

??: ??? ??? ???? ?????.
??:

• constructor(options): ??? ??? ???? ??????.
• _read(size): ???? ??? ???? ?????. ?? ???? ????? null? ???? ??? ??? ????.

?? ???(?????):

??: ? ???? ???? ?????.
??:

• _transform(chunk, ???, ??): ? ??? ??? ???? ???? ???? ??? ??? ?? ????? ?????.

?? ??? ???(ConsoleWritable):

??: ??? ???? ??? ?????.
??:

• _write(chunk, ???, ??): ? ??? ??? ???? ??? ?????. ?? ??? ?????? ??? ?? ??? ?????.

?????:

??: ???? ?? ???? ??? ??? ?????.
??:

• pipeline(readableStream,TransformStream, writableStream, callback): Readable ???? Transform ???? ??? ?? Writable ???? ?????. ??? ???? ???? ?? ???? ?? ??? ?????.

? ???? Node.js ???? ???? ?????? ??? ??? ?? ?????? ??????. Readable ???? ???? ???? Transform ???? ?? ???? Writable ???? ??? ?????. ????? ??? ? ?? ?? ??? ?? ??? ??? ??? ???? ???? ???? ? ?? ??? ? ??? ????.

??

Node.js? ???? ??? ????? ???? ???? ??? ????? ???? ???? ??? ????? ? ??? ???. ???? ?? ????? ???? ??? ???? ?? ?? ???? ???? ??? ??????? ??? ? ????. Node.js? ? ?? ???? RxJS? ?? ?? ?? ??? ???? ??? ?? ??? ??? ???? ? ??? ? ? ????.

?? ??

Node.js?? ???? ? ??? ????? ??? ?????.

• ??? ??? ?? ??: ??? ?????? ?? ??, ?? ? ?? ???? ??? ???.
• Node.js ??? API? ?????. ??? ??? ?? ?? ??? Node.js ??? ??? ?????.
• ??? ???? ?? ????? https://www.reactive-streams.org/
• ?? ????? ??? ??: ??? ?? ??????? ??? ??? ?? ? ?? ??????? ???? ???? ?? ??? ????.
• ?? ?? ??? ????: RxJS?? ???? ?? ?? ?? ?? ???? ???? ?? ??? ???? Node.js? ? ?? ??? ???? ??? ?????.

???? ????? Node.js ??????? ????? ??? ??? ?? ??? ? ????? ??? ? ????.

? ??? ??? ???: Node.JS?? ??? ?????? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!