/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package jdk.incubator.sql2;

import java.time.Duration;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.Flow;
import java.util.function.Consumer;

public interface RowPublisherOperation<T> extends Operation<T> {

  /**
   * * DRAFT Subscribe to the stream of Rows returned by this Operation. The
   * result of this Operation is the value of the {@code result} parameter.
   *
   * @param subscriber Not null.
   * @param result Not null.
   * @return this RowPublisherOperation
   */
  public RowPublisherOperation<T> subscribe(Flow.Subscriber<? super Result.RowColumn> subscriber,
                                            CompletionStage<? extends T> result);
  // Covariant overrides
  
  @Override
  public RowPublisherOperation<T> onError(Consumer<Throwable> handler);
  
  @Override
  public RowPublisherOperation<T> timeout(Duration minTime);
  
}