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