Nodejs

Question

'da bir Tamponun ReadableStream'e Dönüştürülmesi Buffers ve ReadableStreams için oldukça yeniyim, bu yüzden bu aptalca bir sorudur. ReadableStream girişi olarak alan bir kitaplığım var, ancak girdim yalnızca bir base64 biçimindeki bir resim. Ben şöyle bir Tampon içinde ben verileri dönüştürmek olabilir:

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

Ama ReadableStream dönüştürmek veya bir ReadableStream elde edilen Tampon dönüştürmek için nasıl hiçbir fikrim yok.

Bunu yapmanın bir yolu var mı yoksa imkansızı başarmaya mı çalışıyorum?

Teşekkürler.

Answer 1

Öyle gibi Node Stream Buffers kullanarak bir ReadableStream oluşturabilirsiniz:

// 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"); 

frekans 0 nedenle bu belli bir gecikme tanıtacak olamaz.

Answer 2

Node Stream Buffer açıkça testlerde kullanılmak üzere tasarlanmıştır; bir gecikmeyi önleyememe, üretim kullanımı için zayıf bir seçim yapar. okunabilir streamin _read işlevi adım adım push bunu altta yatan bir kaynaktan veri toplamak ve gerektiği, genel esnasında

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 

... böyle How to wrap a buffer as a stream2 Readable stream?

Answer 3

şey:

Gabriel Llamas bu yanıtında streamifier anlaşılacağı Gerekli olmadan önce büyük bir kaynağı belleğe almamanızı sağlar.

Bu durumda, zaten belleğe sahip olduğunuz halde, _read gerekli değildir.

Tüm arabellek yalnızca okunabilir akış api'sine kaydırılıyor.

Answer 4

streamifier modülünü kullanarak basit bir çözümdür.

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

Bunu argümanlar olarak Strings, Tampon ve Nesne kullanabilirsiniz.