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 and Description
OperatorWriteBytes()
OperatorWriteBytes(java.io.File file, boolean append)
OperatorWriteBytes(java.io.File file, boolean append, int bufferSize)
OperatorWriteBytes(int bufferSize)
OperatorWriteBytes(java.io.OutputStream out, boolean closeOnTerminate)
OperatorWriteBytes(java.io.OutputStream out, boolean closeOnTerminate, int bufferSize)

Method Summary

Modifier and Type	Method and Description
rx.Subscriber<? super byte[]>	call(rx.Subscriber<? super java.lang.String> child)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)

Method Detail

call

public rx.Subscriber<? super byte[]> call(rx.Subscriber<? super java.lang.String> child)

Specified by:

call in interface rx.functions.Func1<rx.Subscriber<? super java.lang.String>,rx.Subscriber<? super byte[]>>