Возврат наблюдаемого объекта внутреннего блока

Если вы хотите вернуть наблюдаемую, которая испускает поток с наивысшим качеством за последнюю неделю, функция, которую вы передаете оператору map, должна возвращать значение (как упоминалось в других ответах).

Кроме того, вам необходимо решить, какое поведение следует ожидать при отсутствии потоков. Должна ли результирующая наблюдаемая быть пустой? Или он должен излучать null?

Внутренней подписки, вероятно, лучше избегать - вы будете делать дополнительную подписку с каждым звонком, и указанная подписка никогда не будет отменена. И было бы лучше избежать побочного эффекта, так как высочайшее качество будет доступно за счет эмитируемого потока.

Вместо этого вы можете сделать что-то вроде этого:

getWeeksBest(): Observable<any> {

    let now = Date.now() / 1000;
    let best = this.af.database.list('/threads', {
        query: {
            orderByChild: 'created',
            startAt: now - 604800 //One week ago
        }
    })

    // Filter out empty lists of threads, so that the resultant
    // observable emits nothing if there are no threads:

    .filter(threads => threads.length > 0)

    // Use Array.prototype.reduce to return the thread with the
    // highest quality:

    .map(threads => threads.reduce(
      (acc, thread) => thread.quality > acc.quality ? thread : acc
    ));
    return best;
}

Если вы хотите выдать null, если потоков нет, удалите filter и измените map на:

.map(threads => (threads.length === 0) ? null : threads.reduce(
  (acc, thread) => thread.quality > acc.quality ? thread : acc
))

Таким образом, вопрос, вероятно, заключается в том, почему вы получаете undefined в обратном вызове subscribe(...) в переменной results.

В .map() вы используете синтаксис короткой стрелки для создания блока кода, но это означает, что вы должны использовать оператор return.

.map(results => {
   results.forEach(result => {
       if (result.quality > this.highestWeek) {
           console.log(result) //Logs next highest quality thread
           this.highestWeek = result.quality       
       }
   });
   return results; 
})

В вашем случае я бы даже лучше использовал оператор .do() вместо .map().

В конце getWeeksBest() вы возвращаете Observable, поэтому последняя строка определенно не возвращает undefined.

getWeeksBest(): Observable<any> {
    let now = Date.now() / 1000;
    let results = this.af.database.list('/threads', {
        ...
    });
    return results;
}

RxJS предоставляет множество операторов для преобразования данных. В вашем случае вы хотите получить объект с самым высоким значением quality, поэтому мы можем использовать оператор reduce, где мы применим функцию maxBy().

const weeks = [
    {
      quality: 1
    },
    {
      quality: 15
    },
    {
      quality: 5
    },
    {
      quality: 8
    }
  ];


//maxBy stateless function (you can see a currified function)
const maxBy = (prop) => (a, b) => a[prop] > b[prop] ? a : b;

//Fetch data and apply the maxBy when the reduce is perform over the collection
function fetchData() {
  //You can perform some async actions
  return Rx
    .Observable
    .from(weeks)
    .reduce(maxBy('quality'), 0);
}

fetchData().subscribe(x => console.log(x));

Не стесняйтесь проверить пример на Plunker

Мартин прав, вам нужно добавить оператор return. Но также имейте в виду, что Array.forEach всегда возвращает undefined. Итак, в вашем случае вы можете использовать Array.map.

Но в целом я бы предложил что-то вроде этого:

getAllThreads$(): Observable<any[]> {
  let now = Date.now() / 1000;
  return this.af.database.list('/threads', {
    query: {
        orderByChild: 'created',
        startAt: now - 604800 //One week ago
    }
  })
}

getWeeksBest$():Observable<number>{
  return this.getAllThreads$().map(threads => Array.isArray(threads )? threads.reduce((highestQuality, thread) => {
   let currentQuality = thread? thread.quality: 0;
   return currentQuality > highestQuality? currentQuality: highestQuality;
  }, 0): 0);
}

и где-то в вашем конструкторе классов просто подпишитесь на getWeeksBest$