import { Observable } from 'rxjs'; export declare function mapEachWithEffect(input$: Observable, fn: (value: T) => [U, () => void] | [U]): Observable;