Konwersja bufora na ReadableStream in nodejs

Question

Jestem całkiem nowy w buforach i ReadableStreams, więc może to jest głupie pytanie. Mam bibliotekę, która pobiera jako dane wejściowe wartość ReadableStream, ale moje dane wejściowe są po prostu obrazem w formacie base64. mogę przekonwertować dane mam w buforze tak:

var img = new Buffer(img_string, 'base64'); 

Ale nie mam pojęcia, jak przekonwertować go do ReadableStream lub zamiany bufora I otrzymany w ReadableStream.

Czy istnieje sposób, aby to zrobić, czy staram się osiągnąć niemożliwe?

Dzięki.

Answer 1

Można utworzyć ReadableStream korzystając Node Stream Buffers tak:

// Initialize stream 
var myReadableStreamBuffer = new streamBuffers.ReadableStreamBuffer({ 
    frequency: 10,  // in milliseconds. 
    chunkSize: 2048  // in bytes. 
}); 

// With a buffer 
myReadableStreamBuffer.put(aBuffer); 

// Or with a string 
myReadableStreamBuffer.put("A String", "utf8"); 

częstość nie może być 0, więc będzie to wprowadzać pewne opóźnienie.

Answer 2

Node Stream Buffer jest oczywiście przeznaczony do użytku w testowaniu; niemożność uniknięcia opóźnienia sprawia, że ​​jest to zły wybór do zastosowań produkcyjnych.

Gabriel Llamas sugeruje streamifier w tej odpowiedzi: How to wrap a buffer as a stream2 Readable stream?

Answer 3

coś takiego ...

import { Readable } from 'stream' 

const buffer = new Buffer(img_string, 'base64') 
const readable = new Readable() 
readable._read =() => {} // _read is required but you can noop it 
readable.push(buffer) 
readable.push(null) 

readable.pipe(consumer) // consume the stream 

W ogólnym oczywiście _read funkcja czytelnej Stream powinien zbierać dane z źródle i push ją stopniowo upewniając się, że nie zgromadzisz ogromnego źródła do pamięci, zanim będzie ona potrzebna.

W tym przypadku, chociaż masz już źródło w pamięci, więc _read nie jest wymagane.

Przesunięcie całego bufora powoduje owinięcie go w czytelny api.

Answer 4

Oto proste rozwiązanie przy użyciu modułu streamifier.

const streamifier = require('streamifier'); streamifier.createReadStream(new Buffer ([97, 98, 99])).pipe(process.stdout);

Można używać łańcuchów, bufor i przedmiot jako jej argumenty.