portals-core
API
Generated with
portals-core/portals/portals.compiler/portals.compiler.phases.portal/RewritePortalHelpers

RewritePortalHelpers

portals.compiler.phases.portal.RewritePortalHelpers$
object RewritePortalHelpers

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Type members

Classlikes

class MutApplication(application: Application)

Attributes

Supertypes
class Object
trait Matchable
class Any
class MutWorkflow(workflow: Workflow[_, _])

Attributes

Supertypes
class Object
trait Matchable
class Any

Value members

Concrete methods

def addKeyByWorkflow(path: Path, consumes: AtomicStreamRef[Any], keyF: Any => Long)(using mapp: MutApplication): Workflow[Any, Any]
def addSequencer(path: Path)(using mapp: MutApplication): AtomicSequencer[Any]
def addSplit(path: Path, from: AtomicSplitterRefKind[Any], to: AtomicStreamRefKind[Any], filter: Any => Boolean)(using mapp: MutApplication): AtomicSplit[Any]
def addSplitToPortalSplitter(path: Path, id: String, filter: Any => Boolean)(using mapp: MutApplication): AtomicSplit[Any]
def addSplitter(path: Path, consumes: AtomicStreamRef[Any])(using mapp: MutApplication): AtomicSplitter[Any]
def addTask(path: Path, task: GenericTask[_, _, _, _])(using mwf: MutWorkflow): Unit
def appendConnection(from: Path, to: Path)(using mwf: MutWorkflow): Unit
def connectStreamWithSeq[T](path: Path, stream: AtomicStreamRefKind[Any], sequencerRef: AtomicSequencerRef[Any])(using mapp: MutApplication): AtomicConnection[Any]
def extractAskingPortalRefs(workflow: Workflow[_, _]): Seq[AtomicPortalRefKind[_, _]]
def extractPortalsRefs(workflow: Workflow[_, _]): Seq[AtomicPortalRefKind[_, _]]
def extractReplyingPortalRefs(workflow: Workflow[_, _]): Seq[AtomicPortalRefKind[_, _]]
def extractTasksWithAskerRepliers(workflow: Workflow[_, _]): Map[Path, GenericTask[_, _, _, _]]
def extractTasksWithAsks(workflow: Workflow[_, _]): Map[Path, GenericTask[_, _, _, _]]
def extractTasksWithRepliers(workflow: Workflow[_, _]): Map[Path, GenericTask[_, _, _, _]]
def freshId: String
def hasPortal(workflow: Workflow[_, _]): Boolean
def replacePathWith[T <: AST](path: Path, newItem: T, list: List[T]): List[T]
def taskContainsReplyers(task: GenericTask[_, _, _, _], portalPath: Path): Boolean
def topologicalSort(edges: List[(String, String)]): List[(String, String)]

GENERATED BY CHAT-GPT-3.5

GENERATED BY CHAT-GPT-3.5

Attributes

def updateSource(_source: Path)(using mwf: MutWorkflow): Unit

Extensions

Extensions

extension (path: Path)(path: Path)
def hidden: Path
def id(id: String): Path
def splits: Path
def splitter: Path
def stream: Path
def workflow: Path
Generated with