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 ()

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