chessman

[Trace - 07:37:26 PM] Sending request 'build/initialize - (1)'
Params: {
  "rootUri": "file:///home/ea/src/metals-test/",
  "displayName": "Metals",
  "version": "0.10.8",
  "bspVersion": "2.0.0-M15",
  "capabilities": {
    "languageIds": [
      "scala"
    ]

chessman

package main

import (
	"database/sql"
	"fmt"
	"strconv"
	"strings"
	"time"

	"github.com/google/uuid"

chessman

class MyConsumer(
    groupId: String,
    broker: String
) extends Logging {

  val props = new Properties();
  props.put(KafkaConsumerConf.BOOTSTRAP_SERVERS_CONFIG, broker)
  props.put(KafkaConsumerConf.GROUP_ID_CONFIG, groupId)
  props.put(KafkaConsumerConf.AUTO_OFFSET_RESET_CONFIG, "earliest")

chessman

import com.twitter.{ util => twitter }

path("/") {
  val result = client1.getThings1 flatMap { things1 =>
    ...
    client2.getThings2 flatMap { things2 =>
    ...
    twitter.Future.join(client3.getThings3, client4.getThings4)
  }