score:2
why not create a simple actor that would take in a callback as a constructor arg and then just sit in a:
while( running ) {
callback ( subscriber.recv( 0 ).asinstanceof[array[byte]] )
}
if the speed is not a requirement, you can also look at akka zeromq module, it follows a traditional non blocking message passing. however i found it a lot slower that a vanilla jzmq.
Source: stackoverflow.com
Related Query
- Enforcing Java version for Scala project in sbt?
- Is anyone using Scala in anger (and what advice for a Java programmer)?
- Escaping underscore for Java interoperability in Scala
- Java bytecode decompiler in IntelliJIDEA for Scala
- What advantages does Scala have over Java for concurrent programming?
- scala vs java for Spark?
- To use or not to use Scala for new Java projects?
- Java 7 style automatic resource management for Scala
- How to access a Java static method from Scala given a type alias for that class it resides in
- Setting different spaces for tab for Java and Scala in Eclipse
- Multi-mode XML processors for Java and/or Scala
- Java or Scala for new greenfield projects?
- Scala or Java Library for fixing malformed URIs
- Why simple Scala tailrec loop for fibonacci calculation is faster in 3x times than Java loop?
- Scala or Java equivalent of Ruby factory_girl or Python factory_boy (convenient factory pattern for unit testing)
- Can I use groovy templating instead of scala for Play 2.0 based Java applications?
- Scala - Java interop: can Scala emit enums in bytecode for Java to consume?
- Scala / Java Sandbox for untrusted code
- library for integer factorization in java or scala
- Factory methods for implementations of Java interfaces wrapped with Scala implicits?
- Optimize Scala pattern matching for Java enumeration with @switch
- Best practices for writing a Java library in Scala
- Builder Library for Scala and Java
- Environment for java + scala + lift project in eclipse without maven
- Type-safe Builder Library for Scala and Java
- Scala wrappers for any of Java statistics libraries
- Scala 2.12: What is the equivalent of Java 8 method reference for universally quantified SAM trait?
- Format a double without decimals & adding commas for thousands in Scala Java Play framework
- Scala IDE not working properly in Eclipse Luna for Java EE
- Is it recommended to separate Scala and Java source files for a Maven project?
More Query from same tag
- scala insert to redis gives task not serializable
- Scala partial list of previous elements
- Where is x from?
- play.application.loader [class java.lang.Class}] does not implement interface play.api.ApplicationLoader or interface play.ApplicationLoader
- Package Ruby Library (permailer) as .jar (using JRuby)
- How do you get the POST request object or URL string in Play Framework's WS API?
- iterate throught Dataframe and get the indexes
- Native libraries with Jenkins
- http4s - get request body as String or InputStream
- How to init List of tuple and add item in scala
- Default AkkaSupport Servlet example doesn't work
- Testing with probabilistic failure of components in Akka (Scala)
- Take column names from old dataframe in Spark Scala
- How to split a string on multiple regular expressions while keeping the splitting characters
- Scala: Parsing concatenated XML documents
- What are stackable modifications?
- How to get generic simple class name from scala TypeTag?
- Flink Kryo serializer because Chill serializer couldn't be found
- Why does Scala have path-dependent types?
- Add scala test-case to jar file in maven project
- Surprising PartialFunction literal
- Mixin of invariant type - type mismatch found some other
- Rewrite local var assignment in
- Shapeless Json parsing by LabelledGeneric
- Value :: is not a member of type parameter [T] Scala?
- ReactiveMongo 0.9: Joda Datetime Implicit Conversion for Macros.handler
- returning meaningful error messages from a parser written with Scala Parser Combinators
- Scala and Java BigDecimal
- Sort Spark Dataframe with two columns in different order
- Container Algebraic Data Type in Scala