suspend fun insert(docs: Collection<WriteModel<T>>) {
if (docs.isNotEmpty())
collection().bulkWrite(
- if (docs is List) docs else docs.toList(),
+ docs as? List ?: docs.toList(),
BulkWriteOptions().ordered(false)
)
}
companion object {
operator fun invoke(downstream: TagConsumer<*>) =
- if (downstream is HtmlLexerTagConsumer)
- downstream
- else
- HtmlLexerTagConsumer(downstream)
+ downstream as? HtmlLexerTagConsumer ?: HtmlLexerTagConsumer(downstream)
}
}
fun runScript(scriptName: String, args: Map<String, Any?>, useResult: Consumer<Any?>) {
suspend {
val script = PreProcessorScriptLoader.loadFunction(scriptName)!!
- val argsMutable = if (args is MutableMap) args else args.toMutableMap()
+ val argsMutable = args as? MutableMap ?: args.toMutableMap()
PreProcessorScriptLoader.runScriptInternal(script, argsMutable, env)
}.startCoroutine(Continuation(context) { result ->
result.onSuccess(useResult::accept)