Add `StreamInvoke` to dynamic provider
@@ -65,6 +65,13 @@ async function invokeRPC(call: any, callback: any): Promise<void> {
callback(new Error(`unknown function ${req.getTok()}`), undefined);
}
+async function streamInvokeRPC(call: any, callback: any): Promise<void> {
+ const req: any = call.request;
+
+ // TODO[pulumi/pulumi#406]: implement this.
+ callback(new Error(`unknown function ${req.getTok()}`), undefined);
+}
+
async function checkRPC(call: any, callback: any): Promise<void> {
try {
const req: any = call.request;
@@ -317,6 +324,7 @@ export function main(args: string[]): void {
cancel: cancelRPC,
configure: configureRPC,
invoke: invokeRPC,
+ streamInvoke: streamInvokeRPC,
check: checkRPC,
checkConfig: checkConfigRPC,
diff: diffRPC,
