io.micronaut.function.executor

Class StreamFunctionExecutor<C>

java.lang.Object

io.micronaut.function.executor.AbstractExecutor<C>

io.micronaut.function.executor.StreamFunctionExecutor<C>

Type Parameters:

C - the context type

All Implemented Interfaces:

ApplicationContextProvider, Closeable, AutoCloseable

Direct Known Subclasses:

FunctionApplication

public class StreamFunctionExecutor<C>
extends AbstractExecutor<C>

A base function executor for handling input and output as streams

.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields inherited from class io.micronaut.function.executor.AbstractExecutor

applicationContext

Constructor Summary

Constructors

Constructor and Description
StreamFunctionExecutor()

Method Summary

Modifier and Type	Method and Description
void	execute(InputStream input, OutputStream output) Execute the function for the given input and output.
protected void	execute(InputStream input, OutputStream output, C context) Execute the function with given context object.

Methods inherited from class io.micronaut.function.executor.AbstractExecutor

buildApplicationContext, close, getApplicationContext, newApplicationContextBuilder, resolveFunction, resolveFunctionName, startEnvironment

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamFunctionExecutor

public StreamFunctionExecutor()

Method Detail

execute

public void execute(InputStream input,
                    OutputStream output)
             throws IOException

Execute the function for the given input and output.

Parameters:

input - The input

output - The output

Throws:

IOException - If an I/O exception occurs

execute

protected void execute(InputStream input,
                       OutputStream output,
                       C context)
                throws IOException

Execute the function with given context object.

Parameters:

input - The InputStream

output - THe OutputStream

context - The context object

Throws:

IOException - If an error occurs