abstract class BaseRxResourceHandler : BaseResourceHandler
Abstract class extended from BaseResourceHandler with extra functionality to receive data from a request and forward it to subscribed Observers
BaseRxResourceHandler()
Abstract class extended from BaseResourceHandler with extra functionality to receive data from a request and forward it to subscribed Observers |
fun emitUpdates(data: ByteArray): Unit
Instructs the internal PublishSubject to emit data. This method is intended to be used inside handlers that extend the BaseRxResourceHandler when an onPost is override |
|
fun observeUpdates(): Observable<ByteArray>
Gets an Observable that will emit the data from the body of the incoming requests. The source of the data(POST, PUT request etc.) depends on the implementation of the class that extends BaseRxResourceHandler |
open fun onDelete(request: IncomingRequest, responseBuilder: OutgoingResponseBuilder): Single<OutgoingResponse>
Handler for request of DELETE |
|
open fun onGet(request: IncomingRequest, responseBuilder: OutgoingResponseBuilder): Single<OutgoingResponse>
Handler for request of GET |
|
open fun onPost(request: IncomingRequest, responseBuilder: OutgoingResponseBuilder): Single<OutgoingResponse>
Handler for request of POST |
|
open fun onPut(request: IncomingRequest, responseBuilder: OutgoingResponseBuilder): Single<OutgoingResponse>
Handler for request of PUT |