PgStream (Reactive Postgres Client 0.11.2 API)

java.lang.Object
- io.reactiverse.rxjava.pgclient.PgStream<T>

All Implemented Interfaces:

io.vertx.rxjava.core.streams.ReadStream<T>, io.vertx.rxjava.core.streams.StreamBase
```
public class PgStream<T>
extends Object
implements io.vertx.rxjava.core.streams.ReadStream<T>
```
A row oriented stream.
NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

Field Summary

Fields
Modifier and Type Field and Description

static io.vertx.lang.rx.TypeArg<PgStream> __TYPE_ARG

io.vertx.lang.rx.TypeArg<T> __typeArg_0

Fields
Modifier and Type	Field and Description
`static io.vertx.lang.rx.TypeArg<PgStream>`	`__TYPE_ARG`
`io.vertx.lang.rx.TypeArg<T>`	`__typeArg_0`

Constructor Summary

Constructors
Constructor and Description

PgStream(PgStream delegate)

PgStream(PgStream delegate, io.vertx.lang.rx.TypeArg<T> typeArg_0)

Constructors
Constructor and Description
`PgStream(PgStream delegate)`
`PgStream(PgStream delegate, io.vertx.lang.rx.TypeArg<T> typeArg_0)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`close()` Close the stream and release the resources.
`void`	`close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> completionHandler)` Close the stream and release the resources.
`PgStream<T>`	`endHandler(io.vertx.core.Handler<Void> endHandler)`
`boolean`	`equals(Object o)`
`PgStream<T>`	`exceptionHandler(io.vertx.core.Handler<Throwable> handler)`
`io.vertx.rxjava.core.streams.ReadStream<T>`	`fetch(long arg0)`
`PgStream`	`getDelegate()`
`PgStream<T>`	`handler(io.vertx.core.Handler<T> handler)`
`int`	`hashCode()`
`static <T> PgStream<T>`	`newInstance(PgStream arg)`
`static <T> PgStream<T>`	`newInstance(PgStream arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)`
`PgStream<T>`	`pause()`
`PgStream<T>`	`resume()`
`Single<Void>`	`rxClose()` Close the stream and release the resources.
`Observable<T>`	`toObservable()`
`String`	`toString()`

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

Methods inherited from interface io.vertx.rxjava.core.streams.ReadStream
newInstance, newInstance

Methods inherited from interface io.vertx.rxjava.core.streams.StreamBase
newInstance

- Field Detail
  - __TYPE_ARG
```
public static final io.vertx.lang.rx.TypeArg<PgStream> __TYPE_ARG
```
  - __typeArg_0
```
public final io.vertx.lang.rx.TypeArg<T> __typeArg_0
```
- Constructor Detail
  - PgStream
```
public PgStream(PgStream delegate)
```
  - PgStream
```
public PgStream(PgStream delegate,
                io.vertx.lang.rx.TypeArg<T> typeArg_0)
```
- Method Detail
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object
  - getDelegate
```
public PgStream getDelegate()
```
    Specified by:
    
    getDelegate in interface io.vertx.rxjava.core.streams.ReadStream<T>
    
    Specified by:
    
    getDelegate in interface io.vertx.rxjava.core.streams.StreamBase
  - toObservable
```
public Observable<T> toObservable()
```
    Specified by:
    
    toObservable in interface io.vertx.rxjava.core.streams.ReadStream<T>
  - fetch
```
public io.vertx.rxjava.core.streams.ReadStream<T> fetch(long arg0)
```
    Specified by:
    
    fetch in interface io.vertx.rxjava.core.streams.ReadStream<T>
  - exceptionHandler
```
public PgStream<T> exceptionHandler(io.vertx.core.Handler<Throwable> handler)
```
    Specified by:
    
    exceptionHandler in interface io.vertx.rxjava.core.streams.ReadStream<T>
    
    Specified by:
    
    exceptionHandler in interface io.vertx.rxjava.core.streams.StreamBase
  - handler
```
public PgStream<T> handler(io.vertx.core.Handler<T> handler)
```
    Specified by:
    
    handler in interface io.vertx.rxjava.core.streams.ReadStream<T>
  - pause
```
public PgStream<T> pause()
```
    Specified by:
    
    pause in interface io.vertx.rxjava.core.streams.ReadStream<T>
  - resume
```
public PgStream<T> resume()
```
    Specified by:
    
    resume in interface io.vertx.rxjava.core.streams.ReadStream<T>
  - endHandler
```
public PgStream<T> endHandler(io.vertx.core.Handler<Void> endHandler)
```
    Specified by:
    
    endHandler in interface io.vertx.rxjava.core.streams.ReadStream<T>
  - close
```
public void close()
```
    Close the stream and release the resources.
  - close
```
public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> completionHandler)
```
    Close the stream and release the resources.
    
    Parameters:
    
    completionHandler - the completion handler for this operation
  - rxClose
```
public Single<Void> rxClose()
```
    Close the stream and release the resources.
    
    Returns:
  - newInstance
```
public static <T> PgStream<T> newInstance(PgStream arg)
```
  - newInstance
```
public static <T> PgStream<T> newInstance(PgStream arg,
                                          io.vertx.lang.rx.TypeArg<T> __typeArg_T)
```

Class PgStream<T>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface io.vertx.rxjava.core.streams.ReadStream

Methods inherited from interface io.vertx.rxjava.core.streams.StreamBase

Field Detail

__TYPE_ARG

__typeArg_0

Constructor Detail

PgStream

PgStream

Method Detail

toString

equals

hashCode

getDelegate

toObservable

fetch

exceptionHandler

handler

pause

resume

endHandler

close

close

rxClose

newInstance

newInstance