public class ObservableLineStream extends java.lang.Object implements IObservable<java.lang.String>, java.io.Closeable
Modifier and Type | Field and Description |
---|---|
protected byte[] |
buffer |
protected int |
posInBuffer |
Constructor and Description |
---|
ObservableLineStream(java.io.InputStream stream,
Action0 onDispose) |
public ObservableLineStream(java.io.InputStream stream, Action0 onDispose)
public void start()
public java.lang.Thread getTask()
public int read() throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
public java.io.Closeable subscribe(IObserver<java.lang.String> observer)
subscribe
in interface IObservable<java.lang.String>
public IObservable<java.lang.String> where(Predicate<java.lang.String> predicate)
where
in interface IObservable<java.lang.String>
Copyright © 2014. All Rights Reserved.