org.dartlang.vm.service.internal.BlockingRequestSink Class Reference

Inheritance diagram for org.dartlang.vm.service.internal.BlockingRequestSink:

Public Member Functions
	BlockingRequestSink (RequestSink base)
void	add (JsonObject request)
void	close ()
RequestSink	toErrorSink (ResponseSink errorResponseSink, String errorResponseCode, String errorResponseMessage)
RequestSink	toPassthroughSink ()
void	add (JsonObject request)
void	close ()

Detailed Description

A RequestSink that enqueues all requests and can be later converted into a "passthrough" or an "error" RequestSink.

Definition at line 25 of file BlockingRequestSink.java.

Constructor & Destructor Documentation

BlockingRequestSink()

org.dartlang.vm.service.internal.BlockingRequestSink.BlockingRequestSink ( RequestSink  base )

inline

Definition at line 36 of file BlockingRequestSink.java.

                                               {
    this.base = base;
  }

Member Function Documentation

add()

void org.dartlang.vm.service.internal.BlockingRequestSink.add ( JsonObject  request )

inline

Put request into the sink.

Parameters

request

the request to put, not null.

Implements org.dartlang.vm.service.internal.RequestSink.

Definition at line 41 of file BlockingRequestSink.java.

                                      {
    synchronized (queue) {
      queue.add(request);
    }
  }

close()

void org.dartlang.vm.service.internal.BlockingRequestSink.close ( )

inline

Close the communication channel.

Implements org.dartlang.vm.service.internal.RequestSink.

Definition at line 48 of file BlockingRequestSink.java.

                      {
    base.close();
  }

toErrorSink()

RequestSink org.dartlang.vm.service.internal.BlockingRequestSink.toErrorSink ( ResponseSink  errorResponseSink, String  errorResponseCode, String  errorResponseMessage  )

inline

Responds with an error to all the currently queued requests and return a RequestSink to do the same for all the future requests.

Parameters

errorResponseSink

the sink to send error responses to, not null

Definition at line 58 of file BlockingRequestSink.java.

                                                              {
    ErrorRequestSink errorRequestSink = new ErrorRequestSink(errorResponseSink, errorResponseCode,
        errorResponseMessage);
    synchronized (queue) {
      for (JsonObject request : queue) {
        errorRequestSink.add(request);
      }
    }
    return errorRequestSink;
  }

toPassthroughSink()

RequestSink org.dartlang.vm.service.internal.BlockingRequestSink.toPassthroughSink ( )

inline

Returns the passthrough RequestSink.

Definition at line 73 of file BlockingRequestSink.java.

                                         {
    synchronized (queue) {
      for (JsonObject request : queue) {
        base.add(request);
      }
    }
    return base;
  }

---

The documentation for this class was generated from the following file:

• third_party/dart-lang/sdk/pkg/vm_service/java/src/org/dartlang/vm/service/internal/BlockingRequestSink.java