RemoteGrpcPortWriteOperation extends ReceivingOperation { @Override public boolean supportsRestart() { return true; } RemoteGrpcPortWriteOperation(
      FnDataService beamFnDataService,
      String ptransformId,
      IdGenerator bundleIdSupplier,
      Coder<WindowedValue<T>> coder,
      OperationContext context);  RemoteGrpcPortWriteOperation(
      FnDataService beamFnDataService,
      String ptransformId,
      IdGenerator bundleIdSupplier,
      Coder<WindowedValue<T>> coder,
      OperationContext context,
      Supplier<Long> currentTimeMillis); @Override void start(); Consumer<Integer> processedElementsConsumer(); void abortWait(); @Override void process(Object outputElem); @Override void finish(); @Override void abort(); @Override boolean supportsRestart(); int getElementsSent(); @Override String toString();  }
@Test public void testSupportsRestart() { assertTrue(operation.supportsRestart()); }