io.micronaut.function.executor

Class StreamFunctionExecutor<C>

java.lang.Object

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

Type Parameters:

C - the context type

All Implemented Interfaces:

ApplicationContextProvider, java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

FunctionApplication

public class StreamFunctionExecutor<C>
extends java.lang.Object

A base function executor for handling input and output as streams

.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields

Modifier and Type	Field and Description
protected ApplicationContext	applicationContext The current ApplicationContext.

Constructor Summary

Constructors

Constructor and Description
StreamFunctionExecutor()

Method Summary

Modifier and Type	Method and Description
protected ApplicationContext	buildApplicationContext(C context)
void	close()
void	execute(java.io.InputStream input, java.io.OutputStream output) Execute the function for the given input and output.
protected void	execute(java.io.InputStream input, java.io.OutputStream output, C context) Execute the function with given context object.
ApplicationContext	getApplicationContext() Resolves the ApplicationContext for this class.
protected ApplicationContextBuilder	newApplicationContextBuilder() Builds a new builder.
protected ExecutableMethod<java.lang.Object,java.lang.Object>	resolveFunction(LocalFunctionRegistry localFunctionRegistry, java.lang.String functionName) Resolve a function from the LocalFunctionRegistry.
protected java.lang.String	resolveFunctionName(Environment env) Resolves the function name to execution for the environment.
protected Environment	startEnvironment(ApplicationContext applicationContext) Start the environment specified.

Methods inherited from class java.lang.Object

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

Field Detail

applicationContext

protected ApplicationContext applicationContext

The current ApplicationContext.

Constructor Detail

StreamFunctionExecutor

public StreamFunctionExecutor()

Method Detail

execute

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

Execute the function for the given input and output.

Parameters:

input - The input

output - The output

Throws:

java.io.IOException - If an I/O exception occurs

execute

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

Execute the function with given context object.

Parameters:

input - The InputStream

output - THe OutputStream

context - The context object

Throws:

java.io.IOException - If an error occurs

resolveFunction

protected ExecutableMethod<java.lang.Object,java.lang.Object> resolveFunction(LocalFunctionRegistry localFunctionRegistry,
                                                                              java.lang.String functionName)

Resolve a function from the LocalFunctionRegistry.

Parameters:

localFunctionRegistry - The LocalFunctionRegistry

functionName - The function name

Returns:

The method

resolveFunctionName

protected java.lang.String resolveFunctionName(Environment env)

Resolves the function name to execution for the environment.

Parameters:

env - The environment

Returns:

The function name

buildApplicationContext

protected ApplicationContext buildApplicationContext(@Nullable
                                                     C context)

Parameters:

context - A platform specific context object

Returns:

Build the ApplicationContext to use

newApplicationContextBuilder

@NonNull
protected ApplicationContextBuilder newApplicationContextBuilder()

Builds a new builder.

Returns:

The ApplicationContextBuilder

startEnvironment

protected Environment startEnvironment(ApplicationContext applicationContext)

Start the environment specified.

Parameters:

applicationContext - the application context with the environment

Returns:

The environment within the context

getApplicationContext

public ApplicationContext getApplicationContext()

Description copied from interface: ApplicationContextProvider

Resolves the ApplicationContext for this class.

Specified by:

getApplicationContext in interface ApplicationContextProvider

Returns:

The ApplicationContext

close

@PreDestroy
public void close()
                       throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException