anchor.diff:          Multi<Item> inputs = Multi.createFrom().range(0, max)
                   .map(i -> Integer.toString(i))
                   .map(i -> Item.newBuilder().setValue(i).build());
  -        return client.pipe(inputs).onItem().transform(Item::getValue);
  +        return streaming.pipe(inputs).onItem().transform(Item::getValue);
       }
   
   }
  
positive.code:         Multi<Item> inputs = Multi.createFrom().range(0, max)
                  .map(i -> Integer.toString(i))
                  .map(i -> Item.newBuilder().setValue(i).build());
          return client.sink(inputs).onItem().ignore().andContinueWithNull();
      }
  
      @GET
  
negative.code:     @GET
      public Multi<String> invokeSource() {
          // Retrieve a stream
          return streaming.source(Empty.newBuilder().build())
                  .onItem().transform(Item::getValue);
      }
  
  