zarinfam

public static void streamLog(LogReaderStreamer logReaderStreamer){
    logReaderStreamer.read().forEach(logReaderStreamer::stream);
}

zarinfam

interface LogReaderStreamer extends LogReader, LogStreamer {
}

zarinfam

interface LogReader {
    List<String> read();
}

interface LogStreamer {
    void stream(String message);
}

zarinfam

echoConcat[Id]("Hello", "World!")

zarinfam

echoConcat("Hello": Id[String], "World!": Id[String])

zarinfam

trait Monad[F[_]] {
  def pure[A](value: A): F[A]
  def flatMap[A, B](value: F[A])(func: A => F[B]): F[B]
}

zarinfam

type Id[A] = A

zarinfam

def echoConcat[F[_]: Monad](s1: F[String], s2: F[String]): F[String] = for {
  x <- s1
  y <- s2
} yield s"echo $x $y"

echoConcat(Option("Hello"), Option("World!"))

zarinfam

public synchronized void printText(String text) throws PrintingException {
    final PrintTask printTask = new PrintTask();

    PrintingListener printingListener = new PrintingListener() {
        @Override
        public void onSuccess(SuccessResult successResult) {
            printTask.setResult(PrintTask.RESULT_SUCCESS);
        }

        @Override

zarinfam

public synchronized void printText(String text) throws PrintingException {
    final CompletableFuture<SuccessResult> result = new CompletableFuture();

    PrintingListener printingListener = new PrintingListener() {
        @Override
        public void onSuccess(SuccessResult successResult) {
            result.complete(successResult);
        }

        @Override