java.lang.Object
- one.nio.rpc.stream.StreamProxy<S,R>

All Implemented Interfaces:

java.io.DataInput, java.io.DataOutput, java.io.ObjectInput, java.io.ObjectOutput, java.lang.AutoCloseable, BaseStream, BidiStream<S,R>, ReceiveStream<R>, RpcStream, SendStream<S>
```
public final class StreamProxy<S,R>
extends java.lang.Object
implements RpcStream, BidiStream<S,R>
```

Field Summary

Fields
Modifier and Type Field Description

long bytesRead

long bytesWritten

StreamHandler handler

Constructor Summary

Constructors
Constructor Description

StreamProxy(StreamHandler handler)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`int`	`available()`
`void`	`close()`
`private static java.io.IOException`	`exception()`
`void`	`flush()`
`long`	`getBytesRead()`
`long`	`getBytesWritten()`
`java.net.InetSocketAddress`	`getLocalAddress()`
`java.net.InetSocketAddress`	`getRemoteAddress()`
`void`	`invalidate()`
`int`	`read()`
`int`	`read(byte[] b)`
`int`	`read(byte[] b, int off, int len)`
`void`	`read(java.nio.ByteBuffer buf)`
`boolean`	`readBoolean()`
`byte`	`readByte()`
`char`	`readChar()`
`double`	`readDouble()`
`float`	`readFloat()`
`void`	`readFully(byte[] b)`
`void`	`readFully(byte[] b, int off, int len)`
`int`	`readInt()`
`java.lang.String`	`readLine()`
`long`	`readLong()`
`java.lang.Object`	`readObject()`
`short`	`readShort()`
`int`	`readUnsignedByte()`
`int`	`readUnsignedShort()`
`java.lang.String`	`readUTF()`
`R`	`receive()`
`void`	`send(S object)`
`R`	`sendAndGet(S object)`
`long`	`skip(long n)`
`int`	`skipBytes(int n)`
`Socket`	`socket()`
`void`	`write(byte[] b)`
`void`	`write(byte[] b, int off, int len)`
`void`	`write(int b)`
`void`	`write(java.nio.ByteBuffer buf)`
`void`	`writeBoolean(boolean v)`
`void`	`writeByte(int v)`
`void`	`writeBytes(java.lang.String s)`
`void`	`writeChar(int v)`
`void`	`writeChars(java.lang.String s)`
`void`	`writeDouble(double v)`
`void`	`writeFloat(float v)`
`void`	`writeInt(int v)`
`void`	`writeLong(long v)`
`void`	`writeObject(java.lang.Object obj)`
`void`	`writeShort(int v)`
`void`	`writeUTF(java.lang.String s)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - handler
```
public final StreamHandler handler
```
  - bytesRead
```
public long bytesRead
```
  - bytesWritten
```
public long bytesWritten
```
- Constructor Detail
  - StreamProxy
```
StreamProxy(StreamHandler handler)
```
- Method Detail
  - socket
```
public final Socket socket()
```
    Specified by:
    
    socket in interface BaseStream
  - getLocalAddress
```
public final java.net.InetSocketAddress getLocalAddress()
```
    Specified by:
    
    getLocalAddress in interface BaseStream
  - getRemoteAddress
```
public final java.net.InetSocketAddress getRemoteAddress()
```
    Specified by:
    
    getRemoteAddress in interface BaseStream
  - getBytesRead
```
public final long getBytesRead()
```
    Specified by:
    
    getBytesRead in interface BaseStream
  - getBytesWritten
```
public final long getBytesWritten()
```
    Specified by:
    
    getBytesWritten in interface BaseStream
  - invalidate
```
public final void invalidate()
```
    Specified by:
    
    invalidate in interface BaseStream
  - read
```
public final void read(java.nio.ByteBuffer buf)
                throws java.io.IOException
```
    Specified by:
    
    read in interface RpcStream
    
    Throws:
    
    java.io.IOException
  - readObject
```
public final java.lang.Object readObject()
                                  throws java.io.IOException
```
    Specified by:
    
    readObject in interface java.io.ObjectInput
    
    Throws:
    
    java.io.IOException
  - read
```
public final int read()
               throws java.io.IOException
```
    Specified by:
    
    read in interface java.io.ObjectInput
    
    Throws:
    
    java.io.IOException
  - read
```
public final int read(byte[] b)
               throws java.io.IOException
```
    Specified by:
    
    read in interface java.io.ObjectInput
    
    Throws:
    
    java.io.IOException
  - read
```
public final int read(byte[] b,
                      int off,
                      int len)
               throws java.io.IOException
```
    Specified by:
    
    read in interface java.io.ObjectInput
    
    Throws:
    
    java.io.IOException
  - skip
```
public final long skip(long n)
                throws java.io.IOException
```
    Specified by:
    
    skip in interface java.io.ObjectInput
    
    Throws:
    
    java.io.IOException
  - available
```
public final int available()
```
    Specified by:
    
    available in interface java.io.ObjectInput
  - readFully
```
public final void readFully(byte[] b)
                     throws java.io.IOException
```
    Specified by:
    
    readFully in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readFully
```
public final void readFully(byte[] b,
                            int off,
                            int len)
                     throws java.io.IOException
```
    Specified by:
    
    readFully in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - skipBytes
```
public final int skipBytes(int n)
                    throws java.io.IOException
```
    Specified by:
    
    skipBytes in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readBoolean
```
public final boolean readBoolean()
                          throws java.io.IOException
```
    Specified by:
    
    readBoolean in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readByte
```
public final byte readByte()
                    throws java.io.IOException
```
    Specified by:
    
    readByte in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readUnsignedByte
```
public final int readUnsignedByte()
                           throws java.io.IOException
```
    Specified by:
    
    readUnsignedByte in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readShort
```
public final short readShort()
                      throws java.io.IOException
```
    Specified by:
    
    readShort in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readUnsignedShort
```
public final int readUnsignedShort()
                            throws java.io.IOException
```
    Specified by:
    
    readUnsignedShort in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readChar
```
public final char readChar()
                    throws java.io.IOException
```
    Specified by:
    
    readChar in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readInt
```
public final int readInt()
                  throws java.io.IOException
```
    Specified by:
    
    readInt in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readLong
```
public final long readLong()
                    throws java.io.IOException
```
    Specified by:
    
    readLong in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readFloat
```
public final float readFloat()
                      throws java.io.IOException
```
    Specified by:
    
    readFloat in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readDouble
```
public final double readDouble()
                        throws java.io.IOException
```
    Specified by:
    
    readDouble in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readLine
```
public final java.lang.String readLine()
                                throws java.io.IOException
```
    Specified by:
    
    readLine in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - readUTF
```
public final java.lang.String readUTF()
                               throws java.io.IOException
```
    Specified by:
    
    readUTF in interface java.io.DataInput
    
    Throws:
    
    java.io.IOException
  - write
```
public final void write(java.nio.ByteBuffer buf)
                 throws java.io.IOException
```
    Specified by:
    
    write in interface RpcStream
    
    Throws:
    
    java.io.IOException
  - writeObject
```
public final void writeObject(java.lang.Object obj)
                       throws java.io.IOException
```
    Specified by:
    
    writeObject in interface java.io.ObjectOutput
    
    Throws:
    
    java.io.IOException
  - write
```
public final void write(int b)
                 throws java.io.IOException
```
    Specified by:
    
    write in interface java.io.DataOutput
    
    Specified by:
    
    write in interface java.io.ObjectOutput
    
    Throws:
    
    java.io.IOException
  - write
```
public final void write(byte[] b)
                 throws java.io.IOException
```
    Specified by:
    
    write in interface java.io.DataOutput
    
    Specified by:
    
    write in interface java.io.ObjectOutput
    
    Throws:
    
    java.io.IOException
  - write
```
public final void write(byte[] b,
                        int off,
                        int len)
                 throws java.io.IOException
```
    Specified by:
    
    write in interface java.io.DataOutput
    
    Specified by:
    
    write in interface java.io.ObjectOutput
    
    Throws:
    
    java.io.IOException
  - writeBoolean
```
public final void writeBoolean(boolean v)
                        throws java.io.IOException
```
    Specified by:
    
    writeBoolean in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - writeByte
```
public final void writeByte(int v)
                     throws java.io.IOException
```
    Specified by:
    
    writeByte in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - writeShort
```
public final void writeShort(int v)
                      throws java.io.IOException
```
    Specified by:
    
    writeShort in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - writeChar
```
public final void writeChar(int v)
                     throws java.io.IOException
```
    Specified by:
    
    writeChar in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - writeInt
```
public final void writeInt(int v)
                    throws java.io.IOException
```
    Specified by:
    
    writeInt in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - writeLong
```
public final void writeLong(long v)
                     throws java.io.IOException
```
    Specified by:
    
    writeLong in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - writeFloat
```
public final void writeFloat(float v)
                      throws java.io.IOException
```
    Specified by:
    
    writeFloat in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - writeDouble
```
public final void writeDouble(double v)
                       throws java.io.IOException
```
    Specified by:
    
    writeDouble in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - writeBytes
```
public final void writeBytes(java.lang.String s)
                      throws java.io.IOException
```
    Specified by:
    
    writeBytes in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - writeChars
```
public final void writeChars(java.lang.String s)
                      throws java.io.IOException
```
    Specified by:
    
    writeChars in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - writeUTF
```
public final void writeUTF(java.lang.String s)
                    throws java.io.IOException
```
    Specified by:
    
    writeUTF in interface java.io.DataOutput
    
    Throws:
    
    java.io.IOException
  - flush
```
public final void flush()
                 throws java.io.IOException
```
    Specified by:
    
    flush in interface BidiStream<S,R>
    
    Specified by:
    
    flush in interface java.io.ObjectOutput
    
    Throws:
    
    java.io.IOException
  - close
```
public final void close()
```
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Specified by:
    
    close in interface BaseStream
    
    Specified by:
    
    close in interface java.io.ObjectInput
    
    Specified by:
    
    close in interface java.io.ObjectOutput
  - receive
```
public final R receive()
                throws java.io.IOException
```
    Specified by:
    
    receive in interface ReceiveStream<S>
    
    Throws:
    
    java.io.IOException
  - send
```
public final void send(S object)
                throws java.io.IOException
```
    Specified by:
    
    send in interface SendStream<S>
    
    Throws:
    
    java.io.IOException
  - sendAndGet
```
public final R sendAndGet(S object)
                   throws java.io.IOException
```
    Specified by:
    
    sendAndGet in interface BidiStream<S,R>
    
    Throws:
    
    java.io.IOException
  - exception
```
private static java.io.IOException exception()
```

Modifier and Type	Field	Description
`long`	`bytesRead`
`long`	`bytesWritten`
`StreamHandler`	`handler`

Class StreamProxy<S,​R>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

handler

bytesRead

bytesWritten

Constructor Detail

StreamProxy

Method Detail

socket

getLocalAddress

getRemoteAddress

getBytesRead

getBytesWritten

invalidate

read

readObject

read

read

read

skip

available

readFully

readFully

skipBytes

readBoolean

readByte

readUnsignedByte

readShort

readUnsignedShort

readChar

readInt

readLong

readFloat

readDouble

readLine

readUTF

write

writeObject

write

write

write

writeBoolean

writeByte

writeShort

writeChar

writeInt

writeLong

writeFloat

writeDouble

writeBytes

writeChars

writeUTF

flush

close

receive

send

sendAndGet

exception

Class StreamProxy<S,R>