Examples of ProtocolWaveletUpdate

org.waveprotocol.box.common.comms.ProtocolWaveletUpdate
Model interface for ProtocolWaveletUpdate. Generated from org/waveprotocol/box/common/comms/waveclient-rpc.proto. Do not edit.
org.waveprotocol.box.common.comms.WaveClientRpc.ProtocolWaveletUpdate

Examples of org.waveprotocol.box.common.comms.ProtocolWaveletUpdate

      // 1. Channel id must be in its own message.
      // 2. Synthesize the open-finished marker that the box server leaves out.
      if (update.hasChannelId()
          && (update.hasCommitNotice() || update.hasMarker() || update.hasSnapshot() || update
              .getAppliedDeltaSize() > 0)) {
        ProtocolWaveletUpdate fake = ProtocolWaveletUpdateJsoImpl.create();
        fake.setChannelId(update.getChannelId());
        update.clearChannelId();
        callback.onUpdate(deserialize(fake));
        callback.onUpdate(deserialize(update));
      } else {
        if (update.hasMarker()) {

View Full Code Here

Examples of org.waveprotocol.box.common.comms.ProtocolWaveletUpdate

      // 1. Channel id must be in its own message.
      // 2. Synthesize the open-finished marker that the box server leaves out.
      if (update.hasChannelId()
          && (update.hasCommitNotice() || update.hasMarker() || update.hasSnapshot() || update
              .getAppliedDeltaSize() > 0)) {
        ProtocolWaveletUpdate fake = ProtocolWaveletUpdateJsoImpl.create();
        fake.setChannelId(update.getChannelId());
        update.clearChannelId();
        callback.onUpdate(deserialize(fake));
        callback.onUpdate(deserialize(update));
      } else {
        callback.onUpdate(deserialize(update));

View Full Code Here

Examples of org.waveprotocol.box.common.comms.WaveClientRpc.ProtocolWaveletUpdate

    final String USER = "thorogood@google.com";
    final String WAVE = "foowave";
    final AtomicBoolean receivedOpenRequest = new AtomicBoolean(false);
    final CountDownLatch responseLatch = new CountDownLatch(2);
    final List<ProtocolWaveletUpdate> responses = Lists.newArrayList();
    final ProtocolWaveletUpdate cannedResponse =
        ProtocolWaveletUpdate.newBuilder().setWaveletName(WAVE).build();


    // Generate fairly dummy RPC implementation.
    WaveClientRpc.ProtocolWaveClientRpc.Interface rpcImpl =
        new WaveClientRpc.ProtocolWaveClientRpc.Interface() {

View Full Code Here

Examples of org.waveprotocol.box.common.comms.WaveClientRpc.ProtocolWaveletUpdate

   * streaming message, then cancelling the RPC.
   */
  public void testCancelStreamingRpc() throws Exception {
    final int TIMEOUT_SECONDS = 5;
    final int MESSAGES_BEFORE_CANCEL = 5;
    final ProtocolWaveletUpdate cannedResponse =
        ProtocolWaveletUpdate.newBuilder().setWaveletName("").build();
    final CountDownLatch responseLatch = new CountDownLatch(MESSAGES_BEFORE_CANCEL);
    final CountDownLatch finishedLatch = new CountDownLatch(1);


    // Generate fairly dummy RPC implementation.

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.