com.yahoo.bard.webservice.async.preresponses.stores

Class NoOpPreResponseStore

java.lang.Object

com.yahoo.bard.webservice.async.preresponses.stores.NoOpPreResponseStore

All Implemented Interfaces:

PreResponseStore

@Singleton
public class NoOpPreResponseStore
extends Object
implements PreResponseStore

A PreResponseStore that doesn't actually do anything. Used as a default binding implementation for the PreResponseStore, allowing users who have no interest in asynchronous requests to set up a Bard instance without having to setup any asynchronous infrastructure.

Constructor Summary

Constructors

Constructor and Description
NoOpPreResponseStore()

Method Summary

Modifier and Type	Method and Description
rx.Observable<PreResponse>	get(String ticket) Returns an Observable over a PreResponse associated with a given ticket.
rx.Observable<String>	save(String ticket, PreResponse preResponse) Saves the specified PreResponse in the store.

Methods inherited from class java.lang.Object

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

Constructor Detail

NoOpPreResponseStore

public NoOpPreResponseStore()

Method Detail

get

public rx.Observable<PreResponse> get(String ticket)

Description copied from interface: PreResponseStore

Returns an Observable over a PreResponse associated with a given ticket. The Observable's payload contains the PreResponse if the given ticket is present in the PreResponseStore otherwise it's just an empty Observable.

In case of any error while connecting to the PreResponseStore, the Observable's onError method gets called with the exception as payload.

Specified by:

get in interface PreResponseStore

Parameters:

ticket - The ticket used to identify a job and it's results

Returns:

An Observable over a PreResponse associated with the given ticket

save

public rx.Observable<String> save(String ticket,
                                  PreResponse preResponse)

Description copied from interface: PreResponseStore

Saves the specified PreResponse in the store. If PreResponse for the given ticket already exists, then that PreResponse will be overwritten. Otherwise, a new ticket-PreResponse mapping is added to the store.

This method returns an Observable with the given ticket as a payload. In case of any error while connecting to the PreResponseStore, the Observable's onError method gets called with the exception as payload.

Specified by:

save in interface PreResponseStore

Parameters:

ticket - The ticket used to identify a job and it's results

preResponse - The PreResponse associated with the given ticket

Returns:

An Observable with the ticket as a payload or an exception in case of an error