Macro reject_upsert_input

macro_rules! reject_upsert_input {
    ($input:expr) => { ... };
    ($input:expr, $curr:expr) => { ... };
}

Reject upsert stream as input.