@Override
  public void processAsync(IncomingMessageEnvelope envelope, MessageCollector collector, TaskCoordinator coordinator, TaskCallback callback) {

  }
Test implementation class for {@link AsyncStreamTask}
samza-core/src/test/java/org/apache/samza/task/MockAsyncStreamTask.java