Event Pipelines


A pipeline, as its name implies, is used to build a series of operations (chain a collection of functions) to be evaluated whenever data is processed through the pipeline. With regard to the Scala debugger API, this occurs whenever an event associated with the pipeline occurs.

Event pipelines are a key component of the high-level API available in the Scala debugger API. Methods like getOrCreateBreakpointRequest and getOrCreateAccessWatchpointRequest return pipelines containing events resulting from the requests. See the other sections and the Scaladoc for more information on individual methods.

Example of Pipeline

A pipeline of BreakpointEventInfo objects will typically be triggered whenever a breakpoint on the target JVM is hit. When that occurs, all operations applied to the pipeline will be evaluated in sequential order.

val s: ScalaVirtualMachine = /* some virtual machine */

// This creates a new pipeline for a breakpoint
val pipeline: IdentityPipeline[BreakpointEventInfo] = 
  s.getOrCreateBreakpointRequest("some/scala/file.scala", 37)

// Triggers whenever a breakpoint is hit
pipeline.foreach(_ => println("A breakpoint occurred!"))

// Triggers explicitly when line 37 of any file is hit
  .filter(_ == 37)
  .foreach(ln => println(s"Line $ln was hit!"))

In the example above, a pipeline was created for a specific breakpoint. From there, two children pipelines were created: one that is triggered whenever a breakpoint occurs and one that is only fully evaluated when a breakpoint occurs on line 37.

Warning on closing pipelines

When closing pipelines for events, the underlying event handlers that funnel events through the pipelines are removed; however, the request to send event data from the target JVM to the debugger still exists until ALL pipelines associated with the request are closed!

You can avoid this problem by providing close with the org.scaladebugger.api.profiles.Contants.CloseRemoveAll flag. This will remove the request and all underlying event handlers. This means that any other pipeline created for the request will also stop receiving events.

val p: IdentityPipeline[BreakpointEventInfo] = /* some breakpoint pipeline */

// Remove the request and ALL underlying event handlers
import org.scaladebugger.api.profiles.Constants.CloseRemoveAll
p.close(data = CloseRemoveAll)