Future<bool> delete(String key) { _destroySubject(key); _streams.remove(key); return _storage.delete(key); }