Yeah. Actually, by that very name. 🙂 stream.PassThrough It’s available with Node 0.10 and later as part of the Streams 2 update (mentioned at the end). It’s also one of the few types from Streams that can be directly instantiated: var pass = new stream.PassThrough(); And, it’s currently documented briefly under API for Stream Implementors … Read more
As it says in the documentation, In order to make a for loop the most efficient way of looping over the lines of a file (a very common operation), the next() method uses a hidden read-ahead buffer. And you can see by looking at the implementation of the csv module (line 784) that csv.reader calls … Read more
Use a MemoryStream. Not sure what your function expects, but to stuff a UTF-8 string into it for example: //Act using (var test_Stream = new MemoryStream(Encoding.UTF8.GetBytes(“whatever”))) { var result = imp.Import(test_Stream); // Assert Assert.IsTrue(result); } EDIT: If you need an Excel file, and you are unable to read files from disk, could you add an … Read more
std::ifstream has a method rdbuf(), that returns a pointer to a filebuf. You can then “push” this filebuf into your stringstream: #include <fstream> #include <sstream> int main() { std::ifstream file( “myFile” ); if ( file ) { std::stringstream buffer; buffer << file.rdbuf(); file.close(); // operations on the buffer… } } EDIT: As Martin York remarks … Read more
Does it make sense to always wrap an InputStream as BufferedInputStream, when I know whether the given InputStream is something other than buffered? No. It makes sense if you are likely to perform lots of small reads (one byte or a few bytes at a time), or if you want to use some of the … Read more
Short-answer: no, but you should. Nothing in the contract of either StreamSubscription or StreamSink requires closing the resources, but some use cases can lead to memory leaks if you don’t close them, even though in some cases, doing so might be confusing. Part of the confusion around these classes is that they are overloaded, and … Read more
ended up figuring it out myself: $input_data = file_get_contents(“php://stdin”);
A Duplex stream can be thought of a readable stream with a writable stream. Both are independent and each have separate internal buffer. The reads and writes events happen independently. Duplex Stream ——————| Read <—– External Source You ——————| Write —–> External Sink ——————| You don’t get what you write. It is sent to another … Read more
As implied in the documentation, some ResponseWriter may implement the Flusher interface. This means you can do something like this : func handle(res http.ResponseWriter, req *http.Request) { fmt.Fprintf(res, “sending first line of data”) if f, ok := res.(http.Flusher); ok { f.Flush() } else { log.Println(“Damn, no flush”); } sleep(10) //not real code fmt.Fprintf(res, “sending second … Read more
I know this is a really old question, but as Google seems to like it I thought it would be worth pointing out that I wrote a Node.js video streaming module (Github, or via NPM) that’s hopefully worth a look too.