com.yahoo.bard.webservice.async

Class MetadataHttpResponseChannel

java.lang.Object

com.yahoo.bard.webservice.async.MetadataHttpResponseChannel

All Implemented Interfaces:

rx.Observer<String>

public class MetadataHttpResponseChannel
extends Object
implements rx.Observer<String>

Handles sending job information to the user.

Constructor Summary

Constructors

Constructor and Description
MetadataHttpResponseChannel(javax.ws.rs.container.AsyncResponse asyncResponse, com.fasterxml.jackson.databind.ObjectWriter writer) Builds a channel for sending metadata requests back to the user.

Method Summary

Modifier and Type	Method and Description
void	onCompleted()
void	onError(Throwable error)
void	onNext(String jobView)

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataHttpResponseChannel

public MetadataHttpResponseChannel(javax.ws.rs.container.AsyncResponse asyncResponse,
                                   com.fasterxml.jackson.databind.ObjectWriter writer)

Builds a channel for sending metadata requests back to the user.

Parameters:

asyncResponse - The asynchronous response via which we send responses back to the user

writer - JSON serializer used to serialize error messages

Method Detail

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface rx.Observer<String>

onError

public void onError(Throwable error)

Specified by:

onError in interface rx.Observer<String>

onNext

public void onNext(String jobView)

Specified by:

onNext in interface rx.Observer<String>