Skip to content

Instantly share code, notes, and snippets.

object TasksExtractingService {
type Commit = String
}
class TasksExtractingServiceImpl(config: Config)(implicit val system: ActorSystem, implicit val materializer: Materializer) extends TasksExtractingService {
import TasksExtractingService._
implicit val timeout: Timeout = 60 seconds // Можно из конфига
private val taskNamePattern = "[a-zA-Z]{3,4}-[0-9]{3,4}".r
case class Commit(id: String, title: String)
val taskNamePattern = "[a-zA-Z]{3,4}-[0-9]{3,4}".r
val commits = Seq(
Commit("1", "TST-123"),
Commit("1", "TST-123"),
Commit("2", "TST-2234"),
Commit("3", "TST-31234"),
Commit("4", "TST-4232"),
package com.bitbucket.fsm
import akka.actor._
import akka.persistence.fsm.PersistentFSM
import akka.persistence.fsm.PersistentFSM._
import akka.stream.ActorMaterializer
import com.bitbucket.fsm.Order._
import scala.concurrent.Future
import scala.reflect._
def doubleSay(what: String): String = s"$what $what"
def capitalize(what: String): String = what.capitalize
def exclaim(what: String): String = s"$what!"
implicit class PipeOps[A](a: A) {
def |>[B] (f: A => B): B = f(a)
}
"hello" |> doubleSay |> capitalize |> exclaim
#!/usr/bin/python3.6
import websocket
import json
url = 'wss://api-invest.tinkoff.ru/openapi/md/v1/md-openapi/ws'
sandbox_token = "???"
def do_nothing(event): pass
.
├── BUILD
├── README.md
├── WORKSPACE
├── generate_graph.sh
└── src
└── main
└── scala
└── demo
├── Conference.scala
package demo
import java.util.concurrent.atomic.AtomicInteger
class IdGenerator {
private val seq = new AtomicInteger(0)
def next(): Int = seq.incrementAndGet()
}
final case class Visitor(id: Int)
load("@io_bazel_rules_scala//scala:scala.bzl", "scala_library", "scala_binary", "scala_test", "scala_test_suite")
scala_binary(
name = 'app_binary',
main_class = 'demo.Main',
deps = [
':app'
]
)
options:
languages: ["java", "scala:2.12.8"]
versionConflictPolicy: fixed
resolvers:
- id: "mavencentral"
type: "default"
url: http://central.maven.org/maven2/
dependencies:
ru.tinkoff:
load("@io_bazel_rules_scala//scala:scala.bzl", "scala_library")
package(default_visibility = ["//visibility:public"])
scala_library(
name = 'config',
deps = [
'//3rdparty/jvm/com/typesafe:config',
],
exports = [