Package au.gov.amsa.util.rx
Class OperatorWriteBytes
- java.lang.Object
-
- au.gov.amsa.util.rx.OperatorWriteBytes
-
- All Implemented Interfaces:
rx.functions.Func1<rx.Subscriber<? super java.lang.String>,rx.Subscriber<? super byte[]>>,rx.functions.Function,rx.Observable.Operator<java.lang.String,byte[]>
public class OperatorWriteBytes extends java.lang.Object implements rx.Observable.Operator<java.lang.String,byte[]>
-
-
Constructor Summary
Constructors Constructor Description OperatorWriteBytes()OperatorWriteBytes(int bufferSize)OperatorWriteBytes(java.io.File file, boolean append)OperatorWriteBytes(java.io.File file, boolean append, int bufferSize)OperatorWriteBytes(java.io.OutputStream out, boolean closeOnTerminate)OperatorWriteBytes(java.io.OutputStream out, boolean closeOnTerminate, int bufferSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description rx.Subscriber<? super byte[]>call(rx.Subscriber<? super java.lang.String> child)
-
-
-
Constructor Detail
-
OperatorWriteBytes
public OperatorWriteBytes(java.io.File file, boolean append)
-
OperatorWriteBytes
public OperatorWriteBytes(java.io.File file, boolean append, int bufferSize)
-
OperatorWriteBytes
public OperatorWriteBytes()
-
OperatorWriteBytes
public OperatorWriteBytes(int bufferSize)
-
OperatorWriteBytes
public OperatorWriteBytes(java.io.OutputStream out, boolean closeOnTerminate)
-
OperatorWriteBytes
public OperatorWriteBytes(java.io.OutputStream out, boolean closeOnTerminate, int bufferSize)
-
-