Skip to content

Instantly share code, notes, and snippets.

@dos65
dos65 / trace
Created January 26, 2023 15:40
2023.01.26 17:37:50 ERROR text document: jar:file:///home/v.chelyshov/.cache/coursier/v1/https/nexus.tcsbank.ru/repository/mvn-maven-proxy/com/typesafe/akka/akka-http_2.13/10.2.4/akka-http_2.13-10.2.4-sources.jar!/akka/http/scaladsl/server/package.scalajava.nio.channels.ClosedChannelException
at sun.nio.ch.FileChannelImpl.ensureOpen(FileChannelImpl.java:150)
at sun.nio.ch.FileChannelImpl.position(FileChannelImpl.java:349)
at sun.nio.ch.FileChannelImpl.position(FileChannelImpl.java:52)
at jdk.nio.zipfs.ZipFileSystem.readFullyAt(ZipFileSystem.java:975)
at jdk.nio.zipfs.ZipFileSystem.readFullyAt(ZipFileSystem.java:968)
at jdk.nio.zipfs.ZipFileSystem$EntryInputStream.initDataPos(ZipFileSystem.java:1899)
at jdk.nio.zipfs.ZipFileSystem$EntryInputStream.read(ZipFileSystem.java:1837)
at jdk.nio.zipfs.ZipFileSystem$3.fill(ZipFileSystem.java:1784)
at java.util.zip.InflaterInputStream.read(InflaterInputStream.java:159)
{ "name" : "x", "age": 10 }
{ "name" : "y", "age": 20 }
{ "name" : "z", "age": 30 }
object Example extends MistFn {
// an arguments that extracts Map[String, String]
val mapArg = allArgs.andThen(params => {
val r = params.map({
case (k, v: String) => Right((k,v))
case (k, any) => Left(Failed.InvalidValue(s"$k key contains invalid value: $any"))
}).toSeq
if (r.exists(_.isLeft)) {
import scala.collection.mutable
import scala.collection.mutable.ListBuffer
import scala.reflect.macros.whitebox.Context
import scala.language.experimental.macros
trait Dealised[A] {
def value: A
}
object Dealised {
@dos65
dos65 / Test.scala
Last active December 20, 2017 22:23
sbt - fork in Test
import org.scalatest._
class TestSpec extends FunSpec {
sys.props.get("key") match {
case Some(k) => println(s"ok: $k")
case None => sys.error("non forked")
}
}
@dos65
dos65 / ws_example.html
Created September 6, 2017 13:43
Mist - websocket example
<!DOCTYPE html>
<html>
<head>
<script src="https://code.jquery.com/jquery-3.2.1.js"
integrity="sha256-DZAnKJ/6XZ9si04Hgrsxu/8s717jcIzLy3oi35EouyE="
crossorigin="anonymous"></script>
<script type="text/javascript">
function startJob(f){
$.ajax({
<---- - ищи вот это как комментарии к кускам логов
1 -----------
запуск мастера:
dos65@holy-excalibur:~/projects/mist$ docker run --net=host hydrosphere/mist:0.13.1-1.5.2 mist
17-08-25 20:24:14 [mist-akka.actor.default-dispatcher-4] INFO akka.event.slf4j.Slf4jLogger:80 Slf4jLogger started
17-08-25 20:24:14 [mist-akka.actor.default-dispatcher-4] INFO Remoting:74 Starting remoting
17-08-25 20:24:14 [mist-akka.actor.default-dispatcher-4] INFO Remoting:74 Remoting started; listening on addresses :[akka.tcp://mist@192.168.1.196:2551] <---- вот тут должен быть правильный публичный адрес мастера - не 0.0.0.0
17-08-25 20:24:14 [mist-akka.actor.default-dispatcher-4] INFO Remoting:74 Remoting now listens on addresses: [akka.tcp://mist@192.168.1.196:2551]
function runWs() {
var socket = new WebSocket("ws://localhost:2004/v2/api/jobs/ws");
socket.onopen = function() {
console.log("Connected!")
socket.send("HELLO!")
};
socket.onmessage = function(event) {
console.log(event.data);
};
socket.onclose = function(event) {
<code_scheme name="scala">
<XML>
<option name="XML_LEGACY_SETTINGS_IMPORTED" value="true" />
</XML>
<codeStyleSettings language="Scala">
<option name="ALIGN_MULTILINE_PARAMETERS" value="false" />
</codeStyleSettings>
</code_scheme>
scala> val f = if (_:Boolean) (_:Int) else (_:Int)
f: (Boolean, Int, Int) => Int = <function3>
scala> f(false, 2, 3)
res27: Int = 3
// почему в этом случае 2 аргумента и 2ой функция?
scala> val f2 = if (_:Boolean) (_:Int) + 1 else (_:Int) + 2
f2: Boolean => (Int => Int) = <function1>