Module com.iamsoft.fixparser

Package com.iamsoft.fixparser

Class ContentToFixMsgsFunction

java.lang.Object

com.iamsoft.fixparser.ContentToFixMsgsFunction

All Implemented Interfaces:

BiFunction<MsgLogSpec,InputStream,Stream<MsgRow>>

public final class ContentToFixMsgsFunction
extends Object
implements BiFunction<MsgLogSpec,InputStream,Stream<MsgRow>>

Field Summary

Fields

Modifier and Type	Field	Description
static final ContentToFixMsgsFunction	INSTANCE

Method Summary

Modifier and Type	Method	Description
void	addClassLoader(ClassLoader pClassLoader)
Stream<MsgRow>	apply(MsgLogSpec pSpec, InputStream pContentStream)
Stream<MsgRow>	apply(MsgLogSpec pSpec, InputStream pContentStream, com.iamsoft.util.ui.javafx.StatusMonitor.ProgressUpdate<Double> pProgressUpdate)
static InputStream	getResourceAsStream(String pName)
void	removeClassLoader(ClassLoader pClassLoader)
MsgRow	toMsgRow(MsgLogSpec pSpec, String pMsgLine)
MsgRow	toMsgRow(MsgLogSpec pSpec, String pMsgLine, IntSupplier pIdxSupplier)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.BiFunction

andThen

Field Details

INSTANCE

public static final ContentToFixMsgsFunction INSTANCE

Method Details

apply

public Stream<MsgRow> apply(MsgLogSpec pSpec,
 InputStream pContentStream)

Specified by:

apply in interface BiFunction<MsgLogSpec,InputStream,Stream<MsgRow>>

apply

public Stream<MsgRow> apply(MsgLogSpec pSpec,
 InputStream pContentStream,
 com.iamsoft.util.ui.javafx.StatusMonitor.ProgressUpdate<Double> pProgressUpdate)

addClassLoader

public void addClassLoader(ClassLoader pClassLoader)

removeClassLoader

public void removeClassLoader(ClassLoader pClassLoader)

toMsgRow

public MsgRow toMsgRow(MsgLogSpec pSpec,
 String pMsgLine)

toMsgRow

public MsgRow toMsgRow(MsgLogSpec pSpec,
 String pMsgLine,
 IntSupplier pIdxSupplier)

getResourceAsStream

public static InputStream getResourceAsStream(String pName)